package com.spx.chapter08;

/**
 * create by undeRdoG on  2022-05-04  14:19
 * 凡心所向，素履以往，生如逆旅，一苇以航。
 */
public class UnionFunctionTest {

    public static void main(String[] args) {
        /*
        * union 将多条流合在一起，前提是每条流的数据类型必须相同
        * 思考：多条流union之后的watermark是怎么样的？
        * 与一个算子接受上游多个算子的watermark一样，union之后的watermark取决于所有流中最小的watermark（木桶原理）
        * */
    }
}
